type golang.org/x/net/http2.stream
28 uses
golang.org/x/net/http2 (current package)
server.go#L443: streams: make(map[uint32]*stream),
server.go#L624: streams map[uint32]*stream
server.go#L675: type stream struct {
server.go#L708: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L1169: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1715: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1965: func (st *stream) isPushed() bool {
server.go#L1971: func (st *stream) endStream() {
server.go#L1987: func (st *stream) copyTrailersToHandlerRequest() {
server.go#L1998: func (st *stream) onReadTimeout() {
server.go#L2008: func (st *stream) onWriteTimeout() {
server.go#L2151: func (st *stream) processTrailerHeaders(f *MetaHeadersFrame) error {
server.go#L2200: func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
server.go#L2207: st := &stream{
server.go#L2236: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2305: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *http.Request, error) {
server.go#L2341: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2449: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2481: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2491: st *stream
server.go#L2498: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2508: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2519: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2524: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2547: stream *stream
server.go#L2602: stream *stream
server.go#L3173: parent *stream
writesched.go#L57: stream *stream